package com.lzq.mq.common.dto;

import com.lzq.mq.common.enums.BrokerMessageSendWay;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;

/**
 * 生产者发送消息的封装类
 */
@Slf4j
@Data
public class MessageDTO {

    /**
     * 主题
     */
    private String topic;

    /**
     * 队列ID
     */
    private Integer queueId = -1;

    /**
     * 消息体
     */
    private byte[] body;

    /**
     * 消息ID
     */
    private String msgId;

    /**
     * 发送方式（同步/异步）
     * @see BrokerMessageSendWay
     */
    private int sendWay;

}
